import pymysql
# 2) 使用PyMySQL 库建立与 MySQL 的连接，并返回一个 db 对象。connect( )方法中的"localhost" 参数为主机名，“root” 参数为连接 MySQL 的用户名，“密码” 参数为 MySQL
# 的连接密码，“test” 参数表示操作的 MySQL 数据库
db = pymysql.connect(host='localhost', user='root', password='123456', port=3306, database='test')
# 3) 使用 connector 对象的 cursor()方法建立对 MySQL 的操作游标
cursor = db.cursor()
# 4) 使用字符串编写完成 SQL 语句。这里的 SQL 语句使用 DELETE FROM 将 employeez表中条件为 age 字段值大于 40 的记录删除
sql = "DELETE FROM EMPLOYEE WHERE AGE>'%d'" % (40)
# 5) 使用 try 和 except 语句执行游标 cursor 的 SQL 语句，并使用 commit( ) 方法提交至MySQL 数据库服务器，rollback。方法表示如果在整个提交过程中出现任何问题，则实现事务性的回滚操作。
try:
    cursor.execute(sql)
    db.commit()
except:
    db.rollback()
# 6) 关闭服务器连接
db.close()